# -*- coding: utf-8 -*-
# @Time : 2019/2/24 20:05
# @Author : chen
# @Site : 
# @File : input.py
# @Software: PyCharm

from test.redis_queue import RedisQueue
import time

q = RedisQueue('rq')  # 新建队列名为rq
for i in range(5):
    q.put(i)
    print("input.py: data {} enqueue {}".format(i, time.strftime("%c")))
    time.sleep(1)